package hyl.ext.pipe.demo;

import hyl.base.mq.rocket.MyRocketMq;
import hyl.ext.pipe.CCConfig;
import hyl.ext.pipe.CCFrame;

public class testmain {
	public static void main(String[] args) throws Exception {
		testmain t=	new testmain ();
		t.send();
		//t. receive();
		
	}
	
	public void receive() throws Exception {
		CCConfig ccc=	CCConfig.getInstance();
		CCFrame ccm=ccc.getFrame("hyl_circuit_test");
		ccm.start();
	}
	public void send() throws Exception {
		CCConfig ccc=	CCConfig.getInstance();
		CCFrame ccm=ccc.getFrame("hyl_circuit_test");
		MyRocketMq mqp=ccm.startProducer();
		System.out.println("----开始发送----");
		for(int i=0;i<100;i++) {
			String s="a"+i;
			System.out.println(s);
			mqp.send("1",s.getBytes());
		}
	}
}
